///**
// * 
// */
//package com.cnhaimei.vod.net;
//
//import java.io.ByteArrayOutputStream;
//import java.io.IOException;
//import java.io.UnsupportedEncodingException;
//
//import com.cnhaimei.net.NetSocket;
//import com.cnhaimei.net.TCPSocket;
//import com.cnhaimei.net.NetSocket.SocketDataListener;
//import com.cnhaimei.vod.net.dq.DQPack;
//
///**
// * @author Administrator
// * 
// */
//public class DQControler extends TCPSocket implements SocketDataListener {
//	
//	// /**客户登录*/
//	// public static final byte LOGIN = 0x01;// (暂不支持)
//	/** 断开连接 */
//	public static final byte CUT_CONNECT = 0x02;
//	/** 建立查询 */
//	public static final byte CREATE_SEARCH = 0x03;
//	/** 重新查询 */
//	public static final byte RESEARCH = 0x04;
//	/** 关闭查询 */
//	public static final byte CLOSE = 0x05;
//	/** 读取记录 */
//	public static final byte READ = 0x06;
//	// /**更新记录*/
//	// public static final byte UPDATE = 0x07;// (暂不支持)
//	// /**排序记录*/
//	// public static final byte SORT = 0x08;// (暂不支持)
//	/** 辅助控制 */
//	public static final char SUPCONTROL = 0x09;
//	
//
//	public static final ByteArrayOutputStream ByteOStream = new ByteArrayOutputStream(
//			1024);
//
//	public static final String ENCODING = "GBK";
//
//	public DQControler(String ip, int port) {
//		super(ip, port);
//		// TODO Auto-generated constructor stub
//	}
//
//	public void sendData(DQPack pack) {
//		// TODO Auto-generated method stub
//
//	}
//
//	public void data(NetSocket socket, byte[] head, int headLenth) {
//		// TODO Auto-generated method stub
//	}
//
//	/**
//	 * 发送查询请求包
//	 * 
//	 * @param tableName
//	 * @param query
//	 */
//	public void requestQuery(String tableName, String query) {
//		byte xcmmd = CREATE_SEARCH;
//		byte xargv = 0;
//		try {
//			byte svar[] = new byte[32];
//			byte[] nameBytes = tableName.getBytes(ENCODING);
//			System.arraycopy(nameBytes, 0, svar, 0, nameBytes.length);
//
//			byte[] queryBtyes = query.getBytes(ENCODING);
//
//			byte hSize = (byte) ((queryBtyes.length + 2 + 32) >> 8);
//			byte lSize = (byte) ((queryBtyes.length + 2 + 32) >> 0);
//
//			final ByteArrayOutputStream byteOut = ByteOStream;
//			byteOut.write(xcmmd);
//			byteOut.write(xargv);
//			byteOut.write(hSize);
//			byteOut.write(lSize);
//			byteOut.write(queryBtyes);
//
//			byteOut.writeTo(mOutput);
//
//		} catch (UnsupportedEncodingException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		} catch (IOException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//
//	}
//
//	public void responseQuery() {
//
//	}
//
//	/**
//	 * 读取记录
//	 * @param snap
//	 * @param readFrom
//	 * @param readCount
//	 */
//	public void requestRecord(byte snap, int readFrom, int readCount) {
//		byte xcmmd = READ;
//		byte xargv = snap;// 接收查询应答包接收到的xhead.xargv
//		byte hSize = 0;
//		byte lSize = 8;
//
//		final ByteArrayOutputStream byteOut = ByteOStream;
//		byteOut.write(xcmmd);
//		byteOut.write(xargv);
//		byteOut.write(hSize);
//		byteOut.write(lSize);
//		byteOut.write(readFrom); // 从查询结果的第1条记录开始读取
//		byteOut.write(readCount);// 读取352条记录
//
//		try {
//			byteOut.writeTo(mOutput);
//		} catch (IOException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//	}
//	
//	/**
//	 * 关闭快照
//	 * @param snap
//	 */
//	public void requestClose(byte snap) {
//		byte xcmmd = 5;
//		byte xargv = snap;// 接收读取数据的回应包xhead.xargv
//		byte hSize = 0;
//		byte lSize = 0;
//		
//		final ByteArrayOutputStream byteOut = ByteOStream;
//		byteOut.write(xcmmd);
//		byteOut.write(xargv);
//		byteOut.write(hSize);
//		byteOut.write(lSize);
//		
//		try {
//			byteOut.writeTo(mOutput);
//		} catch (IOException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//
//	}
//
//}
